package com.ada.spark.action

import org.apache.spark.{SparkConf, SparkContext}

/**
  * 作用：在数据集的每一个元素上，运行函数func进行更新。
  */
object Demo11_foreach {
    def main(args: Array[String]): Unit = {
        //创建SparkConf
        val conf = new SparkConf().setAppName("Demo11_foreach").setMaster("local[*]")
        //创建Spark上下文对象
        val sc = new SparkContext(conf)

        var rdd = sc.makeRDD(1 to 5, 2)

        rdd.foreach(println(_))
    }
}
